package com.project.mq.common;

import lombok.Data;

/**
 * 表示一个消费者的上下文环境
 * 表示一个消费者完整的执行环境
 */

@Data
public class ConsumerEnv {
    //消费者的身份标识
    private String consumerTag;
    private String queueName;
    // autoAck: 消息被消费完成后，应答的方式。为 true 自动应答，为 false 手动应答。
    private boolean autoAck;
    //通过这个回调函数来处理收到的消息
    private Consumer consumer;

    public ConsumerEnv(String consumerTag, String queueName, boolean autoAck, Consumer consumer) {
        this.consumerTag = consumerTag;
        this.queueName = queueName;
        this.autoAck = autoAck;
        this.consumer = consumer;
    }

    // 省略 getter setter
}